//package com.example.rocketmq.event.listener;
//
//import lombok.extern.slf4j.Slf4j;
//import org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyContext;
//import org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyStatus;
//import org.apache.rocketmq.client.consumer.listener.MessageListenerOrderly;
//import org.apache.rocketmq.common.message.MessageExt;
//import org.springframework.stereotype.Component;
//
//import java.util.List;
//
///**
// * @author wuancheng
// * @description
// * @date 2021-11-24 09:42:00
// */
//
//@Slf4j
//@Component
//public class MessagePushListener implements MessageListenerOrderly {
//    @Override
//    public ConsumeOrderlyStatus consumeMessage(List<MessageExt> list, ConsumeOrderlyContext consumeOrderlyContext) {
//        for (MessageExt message : list){
//            String jsonStr = new String(message.getBody());
//            String tag = message.getTags();
//            String brokerName = message.getBrokerName();
//            System.out.println(brokerName);
//            log.info(jsonStr+"--"+tag);
//        }
//        return null;
//    }
//}
